package test

import (
	"fmt"
	ir "github.com/garyburd/redigo/redis"
	"server/lib/redis"
	"server/web/model/test"
)

func rtest(r *redis.Redis) string {
	//可以直接使用redis链接
	fmt.Println(r.Get("test"))
	//也可以在申请个链接用于使用
	i := test.Test()
	return i
}

func init() {
	// redis广播接收
	r := redis.Get()
	defer r.Close()
	p := redis.PUB(r)
	p.Subscribe("water")
R:
	for {
		data := p.Receive()
		switch data.(type) {
		case ir.Message:
			fmt.Printf("%s\n", data.(ir.Message).Data)
		case ir.Subscription:
			fmt.Printf("%s\n", data.(ir.Subscription).Channel)
		case error:
			fmt.Println(data)
			break R
		}
		p.Close()
	}
	// fmt.Println(p.Receive())
}
